package com.matrix.common.constant;

/**
 * @author 有点甜
 * @since 2025/8/2
 */
public class RocketMQConstants {
    public static final String IM_PRIVATE_MESSAGE_TOPIC = "IM_PRIVATE_MESSAGE_TOPIC";
    public static final String IM_SYSTEM_MESSAGE_TOPIC = "IM_SYSTEM_MESSAGE_TOPIC";
    public static final String IM_PRIVATE_MESSAGE_CONSUMER_GROUP = "matrix-im-private-consumer-group";
    public static final String IM_SYSTEM_MESSAGE_CONSUMER_GROUP = "matrix-im-system-consumer-group";
    public static final String ORDER_PAY_TIMEOUT_TOPIC = "ORDER_PAY_TIMEOUT_TOPIC";
    public static final String ORDER_PAY_TIMEOUT_CONSUMER_GROUP = "matrix-order-timeout-group";
    public static final String SHOP_INFO_UPDATE_TOPIC = "SHOP_INFO_UPDATE_TOPIC";
    public static final String SHOP_INFO_UPDATE_CONSUMER_GROUP = "matrix-shop-info-update-group";
    public static final String REVIEW_STATS_TOPIC = "REVIEW_STATS_TOPIC";
    public static final String REVIEW_STATS_CONSUMER_GROUP = "matrix-review-stats-group";
    public static final String ORDER_CREATION_TOPIC = "ORDER_CREATION_TOPIC";
    public static final String ORDER_CREATION_CONSUMER_GROUP = "matrix-order-creation-group";
    public static final String PRODUCT_STOCK_DEDUCT_TOPIC = "PRODUCT_STOCK_DEDUCT_TOPIC";
    public static final String PRODUCT_STOCK_DEDUCT_CONSUMER_GROUP = "matrix-product-stock-deduct-group";
    public static final String PRODUCT_CACHE_SYNC_TOPIC = "CACHE_SYNC_TOPIC";
    public static final String PRODUCT_CACHE_SYNC_CONSUMER_GROUP = "matrix-product-cache-sync-group";

}
